package com.yulan;

import com.yulan.threadPool.thread.FixLinkedBlockingQueue;
import org.junit.Test;

public class testLinkedBlockingQueue {

    @Test
    public void testExtend(){
        FixLinkedBlockingQueue<Integer> fixLinkedBlockingQueue = new FixLinkedBlockingQueue<>(100);

        for(int i = 0; i< 150 ; i++){
            fixLinkedBlockingQueue.add(i);



            if(i == 99)
                fixLinkedBlockingQueue.setCapacity(200);


        }
    }
}
